package org.spring.boot.rabbitmq.receive;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.spring.boot.rabbitmq.dto.KaasEvent;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author: eastcom
 * @desc:
 **/
@Component

public class ReceiverMessage {

	protected Logger logger = LoggerFactory.getLogger(this.getClass());

//	@RabbitListener(queues = {"CACHE.GNMS","CACHE.SMS","CACHE.WLAN"})
	public void process(Object message){
		if(message instanceof String){
			logger.info("string message is {}", message);
		}
		if(message instanceof KaasEvent){
			logger.info("event message is {}", message);
		}
		if(message instanceof Byte[]){
			logger.info("byte[] message is {}", message);
		}

	}

}
